home *** CD-ROM | disk | FTP | other *** search
/ Language/OS - Multiplatform Resource Library / LANGUAGE OS.iso / cpp_libs / rjs.lha / RJS / Transport / src / Transport.C < prev    next >
C/C++ Source or Header  |  1991-06-14  |  2KB  |  97 lines
  1. #include <libc.h>
  2. #include <osfcn.h>
  3. #include <sys/uio.h>
  4. #include <iostream.h>
  5. #include <errno.h>
  6.  
  7. #include "Transport.h"
  8. #include <RJS/Util.h>
  9.  
  10. RJS_Transport::RJS_Transport()
  11. {
  12.   td       = -1;
  13.   ss_set(SS_success);
  14.   return_on_error=0;
  15. }
  16.  
  17. int RJS_Transport::close()
  18. {
  19.   if (td == -1) { ss_set(SS_success); return 1; }
  20.   int s = ::close(td);
  21.   if (s==-1) {
  22.     ss_set(RJS_Status(errno));
  23.     if (return_on_error) return 0;
  24.     RJS_Util::crash_and_burn("RJS_Transport","close",ss_message());
  25.   }
  26.   else {
  27.     ss_set(SS_success);
  28.     td=-1;
  29.     return 1;
  30.   }
  31. }
  32.  
  33. int RJS_Transport::ok()
  34. { 
  35.     if (td==-1) return 0;
  36.     else return RJS_Status::ss_ok();
  37. }
  38.  
  39. int RJS_Transport::inuse()
  40. { 
  41.     return (td!=-1);
  42. }
  43.  
  44. int RJS_Transport::read(char *buffer, int mlen)
  45. {
  46.   if (td == -1) return -1;
  47.   int nbr = ::read(td,buffer,mlen);
  48.   if (nbr==-1) {
  49.     ss_set(RJS_Status(errno));
  50.     if (return_on_error) return nbr;
  51.     RJS_Util::crash_and_burn("RJS_Transport","read",ss_message());
  52.   }
  53.   else ss_set(SS_success);
  54.   return nbr;
  55. }
  56.  
  57. int RJS_Transport::readv(const struct iovec *iov, int iovlen)
  58. {
  59.   if (td == -1) return -1;
  60.   int nbr = ::readv(td,iov,iovlen);
  61.   if (nbr==-1) {
  62.     ss_set(RJS_Status(errno));
  63.     if (return_on_error) return nbr;
  64.     RJS_Util::crash_and_burn("RJS_Transport","readv",ss_message());
  65.   }
  66.   else ss_set(SS_success);
  67.   return nbr;
  68. }
  69.  
  70. int RJS_Transport::write(const char *buffer, int len)
  71. {
  72.   if (td == -1) return -1;
  73.   int nbw = ::write(td,buffer,len);
  74.   if (nbw==-1) {
  75.     ss_set(RJS_Status(errno));
  76.     if (return_on_error) return nbw;
  77.     RJS_Util::crash_and_burn("RJS_Transport","write",ss_message());
  78.   }
  79.   else ss_set(SS_success);
  80.   return nbw;
  81. }
  82.  
  83. int RJS_Transport::writev(const struct iovec *iov, int iovlen)
  84. {
  85.   if (td == -1) return -1;
  86.   int nbw = ::writev(td,iov,iovlen);
  87.   if (nbw==-1) {
  88.     ss_set(RJS_Status(errno));
  89.     if (return_on_error) return nbw;
  90.     RJS_Util::crash_and_burn("RJS_Transport","writev",ss_message());
  91.   }
  92.   else ss_set(SS_success);
  93.   return nbw;
  94. }
  95.  
  96.  
  97.